package com.learn.springcloud.dubbo.consumer;

import lombok.extern.slf4j.Slf4j;
import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Component;

/**
 * @Author: 胡伟
 * @Date: 2020/12/2 16:45
 * @Description:
 */
@Component
@Slf4j
public class KafkaConsumer {
    @KafkaListener(topics = "huwei",groupId = "springcloud-dubbo-test")
    public void testConsumer(String message){
        System.out.println("我消费了----->"+message);
        log.info("我来消费了------->{}",message);
    }
}
